package com.edata.bigdata.flink

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}
import org.apache.log4j.Logger

trait Sink[T] extends Serializable {
  @transient lazy val LOGGER = Logger.getLogger(this.getClass)
  var env: StreamExecutionEnvironment
  def sink(dataStream: DataStream[T]): Unit
}
